# coding=utf-8
# !/usr/bin/python
import json
# 接口请求示例为：http://open.api.tianyancha.com/services/open/ic/baseinfoV2/2.0?keyword=中航重机股份有限公司
import requests
import Logger
from urllib.parse import quote_plus
from schedule import every, repeat

log = Logger.logger()
def search_company():

    # 企业协查 针对被告存在法人的案件，模拟书记员操作自动进入企查查/天眼查等第三方系统进行企业地址和联系方式的协查；
    @repeat(every().minutes)
    def get_company_info():
        # todo： 获取被告人存在法人的案件 且还未协查过的的案件
        print("企业协查 针对被告存在法人的案件，模拟书记员操作自动进入企查查/天眼查等第三方系统进行企业地址和联系方式的协查；")
        #  token可以从 数据中心 -> 我的接口 中获取
        token = '65974943-09e7-4be3-99e0-22e0c82c8dee'
        url = "http://open.api.tianyancha.com/services/open/ic/baseinfoV2/2.0?keyword="
        param = quote_plus("洛阳知牛")
        url = url + param
        headers = {'Authorization': token}
        response = requests.get(url, headers=headers)
        if response.status_code != 0:
            text = json.loads(response.text)
            error_code = text["error_code"]
            reason = text["reason"]
            print('获取企业信息失败：失败码：{},失败信息：{}' .format(error_code, reason))
            return
        # 结果打印
        # 企业注册地址
        regLocation = response.result.regLocation
        # print(regLocation)
        # 企业联系方式
        phoneNumber = response.result.phoneNumber
        # print(phoneNumber)
        # TODO:调用华宇接口 发送地址确认书

        # todo： 调用华宇接口 获取地址确认书电子送达结果 根据是否确认查收 将反馈存储在java端


